/*    */ package com.bj58.analysis.track.format;
/*    */ 
/*    */ import org.apache.hadoop.fs.Path;
/*    */ import org.apache.hadoop.io.LongWritable;
/*    */ import org.apache.hadoop.io.Text;
/*    */ import org.apache.hadoop.io.compress.CompressionCodec;
/*    */ import org.apache.hadoop.io.compress.CompressionCodecFactory;
/*    */ import org.apache.hadoop.mapreduce.InputSplit;
/*    */ import org.apache.hadoop.mapreduce.JobContext;
/*    */ import org.apache.hadoop.mapreduce.RecordReader;
/*    */ import org.apache.hadoop.mapreduce.TaskAttemptContext;
/*    */ import org.apache.hadoop.mapreduce.lib.input.FileInputFormat;
/*    */ 
/*    */ 
/*    */ 
/*    */ 
/*    */ 
/*    */ 
/*    */ 
/*    */ public class TrackInputFormat
/*    */   extends FileInputFormat<LongWritable, Text>
/*    */ {
/*    */   public RecordReader<LongWritable, Text> createRecordReader(InputSplit split, TaskAttemptContext context)
/*    */   {
/* 25 */     return new TrackRecordReader();
/*    */   }
/*    */   
/*    */   protected boolean isSplitable(JobContext context, Path file)
/*    */   {
/* 30 */     CompressionCodec codec = new CompressionCodecFactory(context.getConfiguration()).getCodec(file);
/* 31 */     return codec == null;
/*    */   }
/*    */ }


/* Location:              C:\Users\zhaoxiang\Desktop\basestat_log_common_tools-0.3.jar!\com\bj58\analysis\track\format\TrackInputFormat.class
 * Java compiler version: 5 (49.0)
 * JD-Core Version:       0.7.1
 */